package com.cnoc.busi.queue;

import com.alibaba.rocketmq.client.consumer.DefaultMQPushConsumer;
import com.alibaba.rocketmq.client.producer.DefaultMQProducer;

public class MQController {
	DefaultMQPushConsumer consumer;
	DefaultMQProducer producer;

	public long getMessageCount(String topic) throws Exception {
		return 0;
	}
}
